# app/api/gateway.py
from fastapi import APIRouter, Request

router = APIRouter()


@router.post("/message")
async def receive_message(request: Request):
    data = await request.json()
    await request.app.state.message_receiver.process(data)
    return {"status": "ok"}
